GDestroyNotify destroy_notify;
};
-static OstreeRepoCommitFilterResult
-apply_commit_filter (OstreeRepo *self,
+OstreeRepoCommitFilterResult
+_ostree_repo_commit_modifier_apply (OstreeRepo *self,
+ OstreeRepoCommitModifier *modifier,
+ const char *path,
+ GFileInfo *file_info,
+ GFileInfo **out_modified_info)
+{
+ OstreeRepoCommitFilterResult result;
+ GFileInfo *modified_info;
+
+ if (modifier == NULL || modifier->filter == NULL)
+ {
+ *out_modified_info = g_object_ref (file_info);
+ return OSTREE_REPO_COMMIT_FILTER_ALLOW;
+ }
+
+ modified_info = g_file_info_dup (file_info);
+ result = modifier->filter (self, path, modified_info, modifier->user_data);
+ *out_modified_info = modified_info;
+
+ return result;
+}
+
+static gboolean
+apply_commit_filter (OstreeRepo *self,
OstreeRepoCommitModifier *modifier,
GPtrArray *path,
GFileInfo *file_info,
GFileInfo **out_modified_info)
{
GString *path_buf;
- guint i;
OstreeRepoCommitFilterResult result;
- GFileInfo *modified_info;
if (modifier == NULL || modifier->filter == NULL)
{
g_string_append_c (path_buf, '/');
else
{
+ guint i;
for (i = 0; i < path->len; i++)
{
const char *elt = path->pdata[i];
}
}
- modified_info = g_file_info_dup (file_info);
- result = modifier->filter (self, path_buf->str, modified_info, modifier->user_data);
- *out_modified_info = modified_info;
+ result = _ostree_repo_commit_modifier_apply (self, modifier, path_buf->str, file_info, out_modified_info);
g_string_free (path_buf, TRUE);
return result;
#ifdef HAVE_LIBARCHIVE
-static GFileInfo *
-create_modified_file_info (GFileInfo *info,
- OstreeRepoCommitModifier *modifier)
-{
- GFileInfo *ret;
-
- if (!modifier)
- return (GFileInfo*)g_object_ref (info);
-
- ret = g_file_info_dup (info);
-
- return ret;
-}
-
static void
propagate_libarchive_error (GError **error,
struct archive *a)
}
static GFileInfo *
-file_info_from_archive_entry_and_modifier (struct archive_entry *entry,
+file_info_from_archive_entry_and_modifier (OstreeRepo *repo,
+ struct archive_entry *entry,
OstreeRepoCommitModifier *modifier)
{
- GFileInfo *info = g_file_info_new ();
+ gs_unref_object GFileInfo *info = g_file_info_new ();
GFileInfo *modified_info = NULL;
const struct stat *st;
guint32 file_type;
g_file_info_set_attribute_uint32 (info, "unix::rdev", st->st_rdev);
}
- modified_info = create_modified_file_info (info, modifier);
+ _ostree_repo_commit_modifier_apply (repo, modifier,
+ archive_entry_pathname (entry),
+ info, &modified_info);
- g_object_unref (info);
-
return modified_info;
}
}
else
{
- file_info = file_info_from_archive_entry_and_modifier (entry, modifier);
+ file_info = file_info_from_archive_entry_and_modifier (self, entry, modifier);
if (g_file_info_get_file_type (file_info) == G_FILE_TYPE_UNKNOWN)
{
}
#endif
+/**
+ * ostree_repo_write_archive_to_mtree:
+ * @self: An #OstreeRepo
+ * @archive: A path to an archive file
+ * @mtree: The #OstreeMutableTree to write to
+ * @modifier: (allow-none): Optional commit modifier
+ * @autocreate_parents: Autocreate parent directories
+ * @cancellable: Cancellable
+ * @error: Error
+ *
+ * Import an archive file @archive into the repository, and write its
+ * file structure to @mtree.
+ */
gboolean
ostree_repo_write_archive_to_mtree (OstreeRepo *self,
- GFile *archive_f,
- OstreeMutableTree *root,
+ GFile *archive,
+ OstreeMutableTree *mtree,
OstreeRepoCommitModifier *modifier,
gboolean autocreate_parents,
GCancellable *cancellable,
archive_read_support_compression_all (a);
#endif
archive_read_support_format_all (a);
- if (archive_read_open_filename (a, gs_file_get_path_cached (archive_f), 8192) != ARCHIVE_OK)
+ if (archive_read_open_filename (a, gs_file_get_path_cached (archive), 8192) != ARCHIVE_OK)
{
propagate_libarchive_error (error, a);
goto out;
goto out;
}
- if (!write_libarchive_entry_to_mtree (self, root, a,
+ if (!write_libarchive_entry_to_mtree (self, mtree, a,
entry, modifier,
autocreate_parents ? tmp_csum : NULL,
cancellable, error))